package com.canal.starter.transfer;

import com.alibaba.otter.canal.client.CanalConnector;
import com.canal.starter.client.ListenerPoint;
import com.canal.starter.config.CanalProperties;
import com.canal.starter.event.CanalEventListener;

import java.util.List;
import java.util.Map;

/**
 * @author chen.qian
 * @date 2018/3/23
 */
public class DefaultTransponderFactory implements TransponderFactory {
    @Override
    public MessageTransponder newTransponder(CanalConnector connector, Map.Entry<String, CanalProperties.Instance> config, List<CanalEventListener> listeners, List<ListenerPoint> annoListeners) {
        return new DefaultMessageTransponder(connector, config, listeners, annoListeners);
    }
}
